package com.xuecheng.manage_cms.config;


import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @author zhaoxiang
 * @version 1.0
 * @Date 2019/10/16 23:58
 * 生产方的mq配置类只需要配置一个交换机，目的是当交换机不存在时创建一个交换机；
 * 为什么不需要配队列：
 *    因为生产方通过交换机会把消息发送给很多队列，不会具体到某一个；
 */
@Configuration
public class RabbitmqConfig {

    //交换机的名称
    public static final String EXCHANGES_ROUTING_CMS_POSTPAGE="ex_routing_cms_postpage";

    /**
     * 交换机配置使用direct类型
     * @return the exchange
     */
    @Bean(EXCHANGES_ROUTING_CMS_POSTPAGE)
    public Exchange EXCHANGE_TOPICS_INFORM(){
        //durable(true) 持久化，mq重启之后交换机还在
        return ExchangeBuilder.directExchange(EXCHANGES_ROUTING_CMS_POSTPAGE).durable(true).build();
    }
}
